DataFile df = DataFiles.builder(table.schema()) .withPath("/path/to/data/file.parquet") .build(); Table table = new Table(tableLocation, schema); table.newAppend() .appendFile(df) .commit(); Table table = Table.builder() .withCatalog("hadoop.catalog") .withTableIdentifier("my_db.my_table") .build(); Dataset<Row> dataset = table .select("col1", "col2") .filter(expr("col1 > 10")) .as(DataFrameOperations.class) .toDataset();


上一篇:
下一篇:
切换中文