private long getCurrentFileStartIndex(final String absolutePath) {
    final Long id = currentConnectionId.get();
    if (id != null) {
      final Map<String, Long> map = connectionIdToStartIndexRecord.get(id);
      if (map != null && map.containsKey(absolutePath)) {
        return map.get(absolutePath);
      }
    }
    return -1;
  }
Get current FileStartIndex.

@return startIndex of file: -1 if file doesn't exist
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgent.java