File tree Expand file tree Collapse file tree 4 files changed +4
-4
lines changed
spark-3.3/clickhouse-spark/src/main/scala/com/clickhouse/spark/read/format
spark-3.4/clickhouse-spark/src/main/scala/com/clickhouse/spark/read/format
spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/spark/read/format Expand file tree Collapse file tree 4 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ class ClickHouseJsonReader(
3838
3939 override val format : String = " JSONCompactEachRowWithNamesAndTypes"
4040
41- lazy val streamOutput : StreamOutput [Array [JsonNode ]] =
41+ val streamOutput : StreamOutput [Array [JsonNode ]] =
4242 JSONCompactEachRowWithNamesAndTypesStreamOutput .deserializeStream(resp.getInputStream)
4343
4444 override def decode (record : Array [JsonNode ]): InternalRow = {
Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ class ClickHouseBinaryReader(
5151
5252 override val format : String = " RowBinaryWithNamesAndTypes"
5353
54- lazy val streamOutput : Iterator [GenericRecord ] = {
54+ val streamOutput : Iterator [GenericRecord ] = {
5555 val inputString : InputStream = resp.getInputStream
5656 val cbfr : ClickHouseBinaryFormatReader = new RowBinaryWithNamesAndTypesFormatReader (
5757 inputString,
Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ class ClickHouseBinaryReader(
5151
5252 override val format : String = " RowBinaryWithNamesAndTypes"
5353
54- lazy val streamOutput : Iterator [GenericRecord ] = {
54+ val streamOutput : Iterator [GenericRecord ] = {
5555 val inputString : InputStream = resp.getInputStream
5656 val cbfr : ClickHouseBinaryFormatReader = new RowBinaryWithNamesAndTypesFormatReader (
5757 inputString,
Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ class ClickHouseJsonReader(
3838
3939 override val format : String = " JSONCompactEachRowWithNamesAndTypes"
4040
41- lazy val streamOutput : StreamOutput [Array [JsonNode ]] =
41+ val streamOutput : StreamOutput [Array [JsonNode ]] =
4242 JSONCompactEachRowWithNamesAndTypesStreamOutput .deserializeStream(resp.getInputStream)
4343
4444 override def decode (record : Array [JsonNode ]): InternalRow = {
You can’t perform that action at this time.
0 commit comments