co.cask.cdap.data.stream

Class StreamInputSplitFinder.Builder

java.lang.Object

co.cask.cdap.data.stream.StreamInputSplitFinder.Builder

Enclosing class:

StreamInputSplitFinder<T>

public static class StreamInputSplitFinder.Builder
extends Object

Builder for creating a split finder.

Constructor Summary

Constructors

Constructor and Description
StreamInputSplitFinder.Builder(URI path)

Method Summary

Methods

Modifier and Type	Method and Description
<T> StreamInputSplitFinder<T>	build(StreamInputSplitFactory<T> splitFactory) Build the input split finder given a factory for creating splits.
StreamInputSplitFinder.Builder	setEndTime(long endTime)
StreamInputSplitFinder.Builder	setMaxSplitSize(long maxSplitSize)
StreamInputSplitFinder.Builder	setMinSplitSize(long minSplitSize)
StreamInputSplitFinder.Builder	setStartTime(long startTime)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamInputSplitFinder.Builder

public StreamInputSplitFinder.Builder(URI path)

Method Detail

setEndTime

public StreamInputSplitFinder.Builder setEndTime(long endTime)

setStartTime

public StreamInputSplitFinder.Builder setStartTime(long startTime)

setMaxSplitSize

public StreamInputSplitFinder.Builder setMaxSplitSize(long maxSplitSize)

setMinSplitSize

public StreamInputSplitFinder.Builder setMinSplitSize(long minSplitSize)

build

public <T> StreamInputSplitFinder<T> build(StreamInputSplitFactory<T> splitFactory)

Build the input split finder given a factory for creating splits.

Type Parameters:

T - Type of split to find. Expected to be either mapred.InputSplit or mapreduce.InputSplit.

Parameters:

splitFactory - Factory for creating input splits

Returns:

a new instance of StreamInputSplitFinder