SequenceFileBolt |
SequenceFileBolt.addRotationAction(RotationAction action) |
SequenceFileBolt |
SequenceFileBolt.withCompressionCodec(String codec) |
SequenceFileBolt |
SequenceFileBolt.withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType) |
SequenceFileBolt |
SequenceFileBolt.withConfigKey(String configKey) |
SequenceFileBolt |
SequenceFileBolt.withFileNameFormat(FileNameFormat fileNameFormat) |
SequenceFileBolt |
SequenceFileBolt.withFsUrl(String fsUrl) |
SequenceFileBolt |
SequenceFileBolt.withMaxOpenFiles(int maxOpenFiles) |
SequenceFileBolt |
SequenceFileBolt.withPartitioner(Partitioner partitioner) |
SequenceFileBolt |
SequenceFileBolt.withRetryCount(int fileRetryCount) |
SequenceFileBolt |
SequenceFileBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
SequenceFileBolt |
SequenceFileBolt.withSequenceFormat(SequenceFormat format) |
SequenceFileBolt |
SequenceFileBolt.withSyncPolicy(SyncPolicy syncPolicy) |
SequenceFileBolt |
SequenceFileBolt.withTickTupleIntervalSeconds(int interval) |