Skip to content

Commit 2208081

Browse files
authored
Drop the --export-max-records flag (#136)
1 parent a185ed8 commit 2208081

File tree

3 files changed

+0
-19
lines changed

3 files changed

+0
-19
lines changed

backfill-cli/src/main/java/com/datastax/oss/cdc/backfill/admin/BackfillCommand.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -110,14 +110,6 @@ public List<ParameterDescriptor> parameters() {
110110
.type(ParameterType.STRING)
111111
.names(Arrays.asList("--export-consistency"))
112112
.build());
113-
parameters.add(
114-
ParameterDescriptor.builder()
115-
.description(
116-
"The maximum number of records to export from the table. Must be a positive number or -1. "
117-
+ "The default is -1 (export the entire table).")
118-
.type(ParameterType.INTEGER)
119-
.names(Arrays.asList("--export-max-records"))
120-
.build());
121113
parameters.add(
122114
ParameterDescriptor.builder()
123115
.description(

backfill-cli/src/main/java/com/datastax/oss/cdc/backfill/exporter/ExportSettings.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -138,15 +138,6 @@ public char[] getPassword() {
138138
defaultValue = "LOCAL_QUORUM")
139139
public DefaultConsistencyLevel consistencyLevel = DefaultConsistencyLevel.LOCAL_QUORUM;
140140

141-
@Option(
142-
names = "--export-max-records",
143-
paramLabel = "NUM",
144-
description =
145-
"The maximum number of records to export from the table. Must be a positive number or -1. "
146-
+ "The default is -1 (export the entire table).",
147-
defaultValue = "-1")
148-
public int maxRecords = -1;
149-
150141
@Option(
151142
names = "--export-max-concurrent-files",
152143
paramLabel = "NUM|AUTO",

backfill-cli/src/main/java/com/datastax/oss/cdc/backfill/exporter/TableExporter.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -192,8 +192,6 @@ private List<String> createExportArgs(String operationId) {
192192
}
193193
args.add("-url");
194194
args.add(String.valueOf(tableDataDir));
195-
args.add("-maxRecords");
196-
args.add(String.valueOf(settings.exportSettings.maxRecords));
197195
args.add("-maxConcurrentFiles");
198196
args.add(settings.exportSettings.maxConcurrentFiles);
199197
args.add("-maxConcurrentQueries");

0 commit comments

Comments
 (0)