src/com/amazon/kinesis/streaming/agent/tailing/FirehoseFileFlow.java [75:83]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    protected FileTailer<FirehoseRecord> createNewTailer(
            FileCheckpointStore checkpoints,
            ExecutorService sendingExecutor) throws IOException {
        SourceFileTracker fileTracker = buildSourceFileTracker();
        AsyncPublisherService<FirehoseRecord> publisher = getPublisher(checkpoints, sendingExecutor);
        return new FileTailer<FirehoseRecord>(
                agentContext, this, fileTracker,
                publisher, buildParser(), checkpoints);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/com/amazon/kinesis/streaming/agent/tailing/KinesisFileFlow.java [69:77]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public FileTailer<KinesisRecord> createNewTailer(
            FileCheckpointStore checkpoints,
            ExecutorService sendingExecutor) throws IOException {
        SourceFileTracker fileTracker = buildSourceFileTracker();
        AsyncPublisherService<KinesisRecord> publisher = getPublisher(checkpoints, sendingExecutor);
        return new FileTailer<KinesisRecord>(
        		agentContext, this, fileTracker,
                publisher, buildParser(), checkpoints);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -