Skip to content

Commit

Permalink
correct format
Browse files Browse the repository at this point in the history
Signed-off-by: remzi <[email protected]>
  • Loading branch information
HaoYang670 committed Mar 2, 2022
1 parent 95af0cb commit 00d100e
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions java/src/main/native/src/TableJni.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -25,10 +25,10 @@
#include <cudf/groupby.hpp>
#include <cudf/hashing.hpp>
#include <cudf/interop.hpp>
#include <cudf/io/avro.hpp>
#include <cudf/io/csv.hpp>
#include <cudf/io/data_sink.hpp>
#include <cudf/io/json.hpp>
#include <cudf/io/avro.hpp>
#include <cudf/io/orc.hpp>
#include <cudf/io/parquet.hpp>
#include <cudf/join.hpp>
Expand Down Expand Up @@ -1497,9 +1497,10 @@ JNIEXPORT jlongArray JNICALL Java_ai_rapids_cudf_Table_readParquet(JNIEnv *env,
CATCH_STD(env, NULL);
}

JNIEXPORT jlongArray JNICALL Java_ai_rapids_cudf_Table_readAvro(
JNIEnv *env, jclass, jobjectArray filter_col_names,
jstring inputfilepath, jlong buffer, jlong buffer_length, jint unit) {
JNIEXPORT jlongArray JNICALL Java_ai_rapids_cudf_Table_readAvro(JNIEnv *env, jclass,
jobjectArray filter_col_names,
jstring inputfilepath, jlong buffer,
jlong buffer_length, jint unit) {

const bool read_buffer = (buffer != 0);
if (!read_buffer) {
Expand All @@ -1526,10 +1527,9 @@ JNIEXPORT jlongArray JNICALL Java_ai_rapids_cudf_Table_readAvro(
static_cast<std::size_t>(buffer_length)) :
cudf::io::source_info(filename.get());

cudf::io::avro_reader_options opts =
cudf::io::avro_reader_options::builder(source)
.columns(n_filter_col_names.as_cpp_vector())
.build();
cudf::io::avro_reader_options opts = cudf::io::avro_reader_options::builder(source)
.columns(n_filter_col_names.as_cpp_vector())
.build();
return convert_table_for_return(env, cudf::io::read_avro(opts).tbl);
}
CATCH_STD(env, NULL);
Expand Down

0 comments on commit 00d100e

Please sign in to comment.