co.cask.cdap.data.stream

Interface StreamInputSplitFactory<T>

Type Parameters:

T - Type of input split to create. Expected to be mapred.InputSplit or mapreduce.InputSplit.

public interface StreamInputSplitFactory<T>

Factory for creating stream input splits. Generic because mapreduce and mapred apis are separate.

Method Summary

Methods

Modifier and Type	Method and Description
T	createSplit(Path eventPath, Path indexPath, long startTime, long endTime, long start, long length, String[] locations) Create a stream input split.

Method Detail

createSplit

T createSplit(Path eventPath,
            Path indexPath,
            long startTime,
            long endTime,
            long start,
            long length,
            @Nullable
            String[] locations)

Create a stream input split.

Parameters:

eventPath - path of the event file for the split

indexPath - path to the index file for the split

startTime - start timestamp for the split

endTime - end timestamp for the split

start - start position of the file

length - length of the file

locations - locations

Returns:

stream input split