Skip to content

Commit

Permalink
final fixes for #518
Browse files Browse the repository at this point in the history
  • Loading branch information
lepto2014 committed Jun 21, 2024
1 parent ec1c5c4 commit 04c9026
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 7 deletions.
9 changes: 5 additions & 4 deletions cpp/src/filesystem.cc
Original file line number Diff line number Diff line change
Expand Up @@ -172,8 +172,8 @@ Result<T> FileSystem::ReadFileToValue(const std::string& path) const noexcept {
}

template <>
Result<std::string> FileSystem::ReadFileToValue(
const std::string& path) const noexcept {
Result<std::string> FileSystem::ReadFileToValue(const std::string& path) const
noexcept {
GAR_RETURN_ON_ARROW_ERROR_AND_ASSIGN(auto access_file,
arrow_fs_->OpenInputFile(path));
GAR_RETURN_ON_ARROW_ERROR_AND_ASSIGN(auto bytes, access_file->GetSize());
Expand Down Expand Up @@ -311,6 +311,7 @@ Result<std::shared_ptr<FileSystem>> FileSystemFromUriOrPath(
template Result<IdType> FileSystem::ReadFileToValue<IdType>(
const std::string&) const noexcept;
/// template specialization for std::string
template Status FileSystem::WriteValueToFile<IdType>(
const IdType&, const std::string&) const noexcept;
template Status FileSystem::WriteValueToFile<IdType>(const IdType&,
const std::string&) const
noexcept;
} // namespace graphar
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@ class JSONWriteBuilder(
dataSchema: StructType
): OutputWriterFactory = {
val conf = job.getConfiguration
//val parsedOptions = null
val parsedOptions = new JSONOptions(
options,
sqlConf.sessionLocalTimeZone,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@ import org.apache.spark.sql.graphar.json.JSONWriteBuilder
import org.apache.spark.sql.types._
import org.apache.spark.sql.util.CaseInsensitiveStringMap
import org.apache.spark.sql.execution.datasources.json.JsonDataSource
//import org.apache.spark.sql.execution.datasources.v2.json.JsonWrite
import org.apache.spark.sql.catalyst.json.JSONOptions

import scala.collection.JavaConverters._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@ class JSONWriteBuilder(
dataSchema: StructType
): OutputWriterFactory = {
val conf = job.getConfiguration
// val parsedOptions = null
val parsedOptions = new JSONOptions(
options,
sqlConf.sessionLocalTimeZone,
Expand Down

0 comments on commit 04c9026

Please sign in to comment.