external/warc/src/main/java/com/digitalpebble/stormcrawler/warc/GzipHdfsBolt.java
public GzipHdfsBolt addRecordFormat(RecordFormat format, int position) {
        MultipleRecordFormat formats;
        if (this.format == null) {
            formats = new MultipleRecordFormat(format);
            this.format = formats;
        } else {
            if (this.format instanceof MultipleRecordFormat) {
                formats = (MultipleRecordFormat) this.format;
            } else {
                formats = new MultipleRecordFormat(this.format);
                this.format = formats;
            }
            formats.addFormat(new GzippedRecordFormat(format), position);
        }
        return this;
    }
public GzipHdfsBolt addRecordFormat(RecordFormat format, int position) {
        MultipleRecordFormat formats;
        if (this.format == null) {
            formats = new MultipleRecordFormat(format);
            this.format = formats;
        } else {
            if (this.format instanceof MultipleRecordFormat) {
                formats = (MultipleRecordFormat) this.format;
            } else {
                formats = new MultipleRecordFormat(this.format);
                this.format = formats;
            }
            formats.addFormat(new GzippedRecordFormat(format), position);
        }
        return this;
    }
public GzipHdfsBolt addRecordFormat ( RecordFormat format , int position ) { MultipleRecordFormat formats ; if ( this . format == null ) { formats = new MultipleRecordFormat ( format ) ; this . format = formats ; } else { if ( this . format instanceof MultipleRecordFormat ) { formats = ( MultipleRecordFormat ) this . format ; } else { formats = new MultipleRecordFormat ( this . format ) ; this . format = formats ; } formats . addFormat ( new GzippedRecordFormat ( format ) , position ) ; } return this ; }
Add an additional record format at given position
Add an additional record format at given position