Skip to content

Commit 8f07eb4

Browse files
committed
Update ParallelIndexIOConfig.inputFormat to be optional
1 parent 791506e commit 8f07eb4

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

Sources/DataTransferObjects/Druid/indexing/common/task/batch/parallel/ParallelIndexIOConfig.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
11
/// https://druid.apache.org/docs/latest/ingestion/native-batch#ioconfig
22
/// https://github.com/apache/druid/blob/master/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexIOConfig.java
33
public struct ParallelIndexIOConfig: Codable, Hashable, Equatable {
4-
public init(inputFormat: InputFormat, inputSource: InputSource? = nil, appendToExisting: Bool? = nil, dropExisting: Bool? = nil) {
4+
public init(inputFormat: InputFormat?, inputSource: InputSource? = nil, appendToExisting: Bool? = nil, dropExisting: Bool? = nil) {
55
self.inputFormat = inputFormat
66
self.inputSource = inputSource
77
self.appendToExisting = appendToExisting
88
self.dropExisting = dropExisting
99
}
10-
10+
1111
/// inputFormat to specify how to parse input data.
12-
public let inputFormat: InputFormat
12+
public let inputFormat: InputFormat?
1313

1414
public let inputSource: InputSource?
1515

0 commit comments

Comments
 (0)