Examples of ChunkingType

com.linkedin.databus2.relay.config.PhysicalSourceStaticConfig.ChunkingType

Examples of com.linkedin.databus2.relay.config.PhysicalSourceStaticConfig.ChunkingType

    sources[0] = lssc;
    String role = "MASTER";
    long slowSourceQueryThreshold = 0L;
    long restartScnOffset = 0L;
    BackoffTimerStaticConfigBuilder bsc = new BackoffTimerStaticConfigBuilder();
    ChunkingType ct = ChunkingType.NO_CHUNKING;
    long txnsPerChunk = 0L;
    long scnChunkSize = 0L;
    long chunkedScnThreshold = 0L;
    long maxScnDelayMs = 0L;
    long eventRatePerSec = rate;

View Full Code Here

Examples of com.linkedin.databus2.relay.config.PhysicalSourceStaticConfig.ChunkingType

    LogicalSourceStaticConfig[] sourcesStaticConfigs = new LogicalSourceStaticConfig[_sources.size()];
    for (int i = 0 ; i < _sources.size(); ++i)
    {
      sourcesStaticConfigs[i] = _sources.get(i).build();
    }
    ChunkingType chunkingType = ChunkingType.valueOf(_chunkingType);
    return new PhysicalSourceStaticConfig(_name, _id, _uri, _resourceKey,
                                          sourcesStaticConfigs, _role,
                                          _slowSourceQueryThreshold,
                                          _restartScnOffset,
                                          _retries.build(),

View Full Code Here

Examples of com.linkedin.databus2.relay.config.PhysicalSourceStaticConfig.ChunkingType

                    boolean useChunking)
    throws SQLException
  {
    boolean debugEnabled = _log.isDebugEnabled();
    String eventQuery = null;
    ChunkingType type = _chunkingType;


    if ( ! useChunking || (! type.isChunkingEnabled()))
    {
      eventQuery = _eventQueriesBySource.get(source.getSourceId());
    } else {
      if ( type == ChunkingType.SCN_CHUNKING)
          eventQuery = _eventChunkedScnQueriesBySource.get(source.getSourceId());
      else
        eventQuery = _eventChunkedTxnQueriesBySource.get(source.getSourceId());
    }


    if (debugEnabled) _log.debug("source[" + source.getEventView() + "]: " + eventQuery +
          "; skipInfinityScn=" + source.isSkipInfinityScn() + " ; sinceScn=" + sinceScn);


    PreparedStatement pStmt = conn.prepareStatement(eventQuery);
    if ( ! useChunking || (!type.isChunkingEnabled()))
    {
      pStmt.setFetchSize(currentFetchSize);
    pStmt.setLong(1, sinceScn);
    if (! source.isSkipInfinityScn()) pStmt.setLong(2, sinceScn);
    } else {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.