Github user ajantha-bhat commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2837#discussion_r228700968
--- Diff: store/CSDK/src/CarbonWriter.cpp ---
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <stdexcept>
+#include "CarbonWriter.h"
+
+void CarbonWriter::builder(JNIEnv *env) {
+ if (env == NULL) {
+ throw std::runtime_error("JNIEnv parameter can't be NULL.");
+ }
+ jniEnv = env;
+ carbonWriter =
env->FindClass("org/apache/carbondata/sdk/file/CarbonWriter");
+ if (carbonWriter == NULL) {
+ throw std::runtime_error("Can't find the class in java:
org/apache/carbondata/sdk/file/CarbonWriter");
+ }
+ jmethodID carbonWriterBuilderID = env->GetStaticMethodID(carbonWriter,
"builder",
+ "()Lorg/apache/carbondata/sdk/file/CarbonWriterBuilder;");
+ if (carbonWriterBuilderID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
carbonWriterBuilder");
+ }
+ carbonWriterBuilderObject = env->CallStaticObjectMethod(carbonWriter,
carbonWriterBuilderID);
+}
+
+bool CarbonWriter::checkBuilder() {
+ if (carbonWriterBuilderObject == NULL) {
+ throw std::runtime_error("carbonWriterBuilder Object can't be
NULL. Please call builder method first.");
+ }
+}
+
+void CarbonWriter::outputPath(char *path) {
+ if (path == NULL) {
+ throw std::runtime_error("path parameter can't be NULL.");
+ }
+ checkBuilder();
+ jclass carbonWriterBuilderClass =
jniEnv->GetObjectClass(carbonWriterBuilderObject);
+ jmethodID methodID = jniEnv->GetMethodID(carbonWriterBuilderClass,
"outputPath",
+
"(Ljava/lang/String;)Lorg/apache/carbondata/sdk/file/CarbonWriterBuilder;");
+ if (methodID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
outputPath");
+ }
+ jstring jPath = jniEnv->NewStringUTF(path);
+ jvalue args[1];
+ args[0].l = jPath;
+ carbonWriterBuilderObject =
jniEnv->CallObjectMethodA(carbonWriterBuilderObject, methodID, args);
+}
+
+void CarbonWriter::withCsvInput(char *jsonSchema) {
+ if (jsonSchema == NULL) {
+ throw std::runtime_error("jsonSchema parameter can't be NULL.");
+ }
+ checkBuilder();
+ jclass carbonWriterBuilderClass =
jniEnv->GetObjectClass(carbonWriterBuilderObject);
+ jmethodID methodID = jniEnv->GetMethodID(carbonWriterBuilderClass,
"withCsvInput",
+
"(Ljava/lang/String;)Lorg/apache/carbondata/sdk/file/CarbonWriterBuilder;");
+ if (methodID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
withCsvInput");
+ }
+ jstring jPath = jniEnv->NewStringUTF(jsonSchema);
+ jvalue args[1];
+ args[0].l = jPath;
+ carbonWriterBuilderObject =
jniEnv->CallObjectMethodA(carbonWriterBuilderObject, methodID, args);
+ if (jniEnv->ExceptionCheck()) {
+ throw jniEnv->ExceptionOccurred();
+ }
+};
+
+void CarbonWriter::withHadoopConf(char *key, char *value) {
+ if (key == NULL) {
+ throw std::runtime_error("key parameter can't be NULL.");
+ }
+ if (value == NULL) {
+ throw std::runtime_error("value parameter can't be NULL.");
+ }
+ checkBuilder();
+ jclass carbonWriterBuilderClass =
jniEnv->GetObjectClass(carbonWriterBuilderObject);
+ jmethodID methodID = jniEnv->GetMethodID(carbonWriterBuilderClass,
"withHadoopConf",
+
"(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/carbondata/sdk/file/CarbonWriterBuilder;");
+ if (methodID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
withHadoopConf");
+ }
+ jvalue args[2];
+ args[0].l = jniEnv->NewStringUTF(key);
+ args[1].l = jniEnv->NewStringUTF(value);
+ carbonWriterBuilderObject =
jniEnv->CallObjectMethodA(carbonWriterBuilderObject, methodID, args);
+}
+
+void CarbonWriter::writtenBy(char *appName) {
+ checkBuilder();
+ jclass carbonWriterBuilderClass =
jniEnv->GetObjectClass(carbonWriterBuilderObject);
+ jmethodID methodID = jniEnv->GetMethodID(carbonWriterBuilderClass,
"writtenBy",
+
"(Ljava/lang/String;)Lorg/apache/carbondata/sdk/file/CarbonWriterBuilder;");
+ if (methodID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
writtenBy");
+ }
+ jvalue args[1];
+ args[0].l = jniEnv->NewStringUTF(appName);
+ carbonWriterBuilderObject =
jniEnv->CallObjectMethodA(carbonWriterBuilderObject, methodID, args);
+}
+
+void CarbonWriter::build() {
+ checkBuilder();
+ jclass carbonWriterBuilderClass =
jniEnv->GetObjectClass(carbonWriterBuilderObject);
+ jmethodID methodID = jniEnv->GetMethodID(carbonWriterBuilderClass,
"build",
+ "()Lorg/apache/carbondata/sdk/file/CarbonWriter;");
+ if (methodID == NULL) {
+ throw std::runtime_error("Can't find the method in java: build");
+ }
+ carbonWriterObject =
jniEnv->CallObjectMethod(carbonWriterBuilderObject, methodID);
+
+ if (jniEnv->ExceptionCheck()) {
+ throw jniEnv->ExceptionOccurred();
+ }
+}
+
+void CarbonWriter::write(jobject obj) {
+ if (carbonWriterObject == NULL) {
+ throw std::runtime_error("Please call build first.");
+ }
+ if (writeID == NULL) {
+ carbonWriter = jniEnv->GetObjectClass(carbonWriterObject);
+ writeID = jniEnv->GetMethodID(carbonWriter, "write",
"(Ljava/lang/Object;)V");
+ if (writeID == NULL) {
+ throw std::runtime_error("Can't find the method in java:
write");
+ }
+ }
+ jvalue args[1];
+ args[0].l = obj;
+ jniEnv->CallBooleanMethodA(carbonWriterObject, writeID, args);
+ if (jniEnv->ExceptionCheck()) {
+ throw jniEnv->ExceptionOccurred();
+ }
+};
+
+jboolean CarbonWriter::close() {
--- End diff --
return values not changed. This is void.
---
