Package com.onenetwork.platform.integ.msg

Interface DynamicCsvChunker

public interface DynamicCsvChunker
Interface used to dynamically chunk a large integration file into smaller pieces. Instances of this class will be instantiated *once* per file to be processed.

  • Method Summary

    Modifier and Type Method Description
    boolean isNewChunk​(GridTask task, java.util.List<java.lang.String> row, DynamicChunkingContext ctx)
    Return true if the current row is the start of a "new chunk" relative to the last row.
    default boolean useDynamicChunking​(GridTask task, java.lang.Object dvceBatchUploadQueueRow, DynamicChunkingContext ctx)
    Returns true if current IB needs dynamic chunking based runtime logic

  • Method Details

    • isNewChunk

      boolean isNewChunk​(GridTask task, java.util.List<java.lang.String> row, DynamicChunkingContext ctx)
      Return true if the current row is the start of a "new chunk" relative to the last row. The implementation should always return true the first time the method is called after the chunker is instantiated, since the first row is always a new chunk. Beyond that, the implementation may make decisions by looking at values in the row to determine if a new chunk is warranted or not

    • useDynamicChunking

      default boolean useDynamicChunking​(GridTask task, java.lang.Object dvceBatchUploadQueueRow, DynamicChunkingContext ctx)
      Returns true if current IB needs dynamic chunking based runtime logic
      Parameters:
      task -
      dvceBatchUploadQueueRow -
      ctx -
      Returns: