JDBCParquetWriter 1.2.0-SNAPSHOT API

Base Package: com.manticore.jdbc

parquetwriter

JDBCParquetWriter.Dialect(DUCKDB, CLICKHOUSE)

JDBCParquetWriter

extends: Object

JDBCParquetWriter()

writeFileForQueryResult(folder, qryStr, targetTableName, conn, dialect, compressionCodecName) → String

  • File folder

  • String qryStr

  • String targetTableName

  • Connection conn

  • Dialect dialect

  • CompressionCodecName compressionCodecName

  • returns String

writeFilesForQueryTables(folder, qryStr, conn, dialect, compressionCodecName) → String

  • File folder

  • String qryStr

  • Connection conn

  • Dialect dialect

  • CompressionCodecName compressionCodecName

  • returns String

write(file, tableName, conn) → void

  • File file

  • String tableName

  • Connection conn

  • returns void

write(file, tableName, conn, compressionCodecName) → void

  • File file

  • String tableName

  • Connection conn

  • CompressionCodecName compressionCodecName

  • returns void

write(f, tableName, rs) → void

  • File f

  • String tableName

  • ResultSet rs

  • returns void

write(f, tableName, rs, compressionCodecName) → void

  • File f

  • String tableName

  • ResultSet rs

  • CompressionCodecName compressionCodecName

  • returns void

getParquetSchemaFromResultSet(tableName, metadata) → MessageType

  • String tableName

  • ResultSetMetaData metadata

  • returns MessageType

TableNamesFinder

extends: TablesNamesFinder

TableNamesFinder(sqlStr)

  • String sqlStr

getTargetTableName() → String

  • returns String

getSourceTableNames() → Set

  • returns Set

visit(insert) → void

  • Insert insert

  • returns void

visit(merge) → void @Override

  • Merge merge

  • returns void

visit(update) → void

  • Update update

  • returns void

visit(delete) → void @Override

  • Delete delete

  • returns void