Package org.apache.beam.runners.flink.translation.wrappers

Class ImpulseInputFormat

java.lang.Object
org.apache.flink.api.common.io.RichInputFormat<WindowedValue<byte[]>,org.apache.flink.core.io.GenericInputSplit>
org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat
All Implemented Interfaces:
Serializable, org.apache.flink.api.common.io.InputFormat<WindowedValue<byte[]>,org.apache.flink.core.io.GenericInputSplit>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.io.GenericInputSplit>
public class ImpulseInputFormat extends org.apache.flink.api.common.io.RichInputFormat<WindowedValue<byte[]>,org.apache.flink.core.io.GenericInputSplit>
Flink input format that implements impulses.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    ImpulseInputFormat()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    configure(org.apache.flink.configuration.Configuration configuration)
     
    org.apache.flink.core.io.GenericInputSplit[]
    createInputSplits(int numSplits)
     
    org.apache.flink.core.io.InputSplitAssigner
    getInputSplitAssigner(org.apache.flink.core.io.GenericInputSplit[] genericInputSplits)
     
    org.apache.flink.api.common.io.statistics.BaseStatistics
    getStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics baseStatistics)
     
    WindowedValue<byte[]>
    nextRecord(WindowedValue<byte[]> windowedValue)
     
    void
    open(org.apache.flink.core.io.GenericInputSplit genericInputSplit)
     
    boolean
    reachedEnd()
     

    Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

    closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ImpulseInputFormat

      public ImpulseInputFormat()

  • Method Details

    • configure

      public void configure(org.apache.flink.configuration.Configuration configuration)

    • getStatistics

      public org.apache.flink.api.common.io.statistics.BaseStatistics getStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics baseStatistics)

    • createInputSplits

      public org.apache.flink.core.io.GenericInputSplit[] createInputSplits(int numSplits)

    • getInputSplitAssigner

      public org.apache.flink.core.io.InputSplitAssigner getInputSplitAssigner(org.apache.flink.core.io.GenericInputSplit[] genericInputSplits)

    • open

      public void open(org.apache.flink.core.io.GenericInputSplit genericInputSplit)

    • reachedEnd

      public boolean reachedEnd()

    • nextRecord

      public WindowedValue<byte[]> nextRecord(WindowedValue<byte[]> windowedValue)

    • close

      public void close()