Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Transform] rename data frame transform to transform for hlrc client #46933

Merged
merged 12 commits into from
Sep 25, 2019

Conversation

hendrikmuhs
Copy link

@hendrikmuhs hendrikmuhs commented Sep 20, 2019

rename data frame transform to transform for hlrc

@elasticmachine
Copy link
Collaborator

Pinging @elastic/ml-core

@hendrikmuhs hendrikmuhs force-pushed the rename-to-transform-hlrc branch from ee0d428 to 01d1154 Compare September 23, 2019 07:56
@hendrikmuhs hendrikmuhs force-pushed the rename-to-transform-hlrc branch from 4cab2ad to 3618694 Compare September 23, 2019 18:27
@hendrikmuhs
Copy link
Author

run elasticsearch-ci/docs-check

@hendrikmuhs hendrikmuhs marked this pull request as ready for review September 23, 2019 19:47
@hendrikmuhs hendrikmuhs removed the WIP label Sep 23, 2019
@benwtrent benwtrent self-requested a review September 24, 2019 12:17
Copy link
Member

@benwtrent benwtrent left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Minor cosmetic things. Just some indention woes given the rename :)

:%s/data.*frame//gi

private int count;
private InvalidTransforms invalidTransforms;

public GetDataFrameTransformResponse(List<DataFrameTransformConfig> transformConfigurations,
public GetTransformResponse(List<TransformConfig> transformConfigurations,
int count,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#nit indention fix.

Suggested change
int count,
int count,

private int count;
private InvalidTransforms invalidTransforms;

public GetDataFrameTransformResponse(List<DataFrameTransformConfig> transformConfigurations,
public GetTransformResponse(List<TransformConfig> transformConfigurations,
int count,
@Nullable InvalidTransforms invalidTransforms) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
@Nullable InvalidTransforms invalidTransforms) {
@Nullable InvalidTransforms invalidTransforms) {

return PARSER.parse(parser, null);
}

public StartDataFrameTransformResponse(boolean acknowledged, @Nullable List<TaskOperationFailure> taskFailures,
public StartTransformResponse(boolean acknowledged, @Nullable List<TaskOperationFailure> taskFailures,
@Nullable List<? extends ElasticsearchException> nodeFailures) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
@Nullable List<? extends ElasticsearchException> nodeFailures) {
@Nullable List<? extends ElasticsearchException> nodeFailures) {

return PARSER.parse(parser, null);
}

public StopDataFrameTransformResponse(boolean acknowledged, @Nullable List<TaskOperationFailure> taskFailures,
public StopTransformResponse(boolean acknowledged, @Nullable List<TaskOperationFailure> taskFailures,
@Nullable List<? extends ElasticsearchException> nodeFailures) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
@Nullable List<? extends ElasticsearchException> nodeFailures) {
@Nullable List<? extends ElasticsearchException> nodeFailures) {

public DataFrameTransformCheckpointStats(final long checkpoint, final DataFrameIndexerPosition position,
final DataFrameTransformProgress checkpointProgress, final long timestampMillis,
public TransformCheckpointStats(final long checkpoint, final TransformIndexerPosition position,
final TransformProgress checkpointProgress, final long timestampMillis,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
final TransformProgress checkpointProgress, final long timestampMillis,
final TransformProgress checkpointProgress, final long timestampMillis,

Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
String... sourceIndices) throws Exception {
return createTransformConfig(id, groups, aggregations, destinationIndex, QueryBuilders.matchAllQuery(), sourceIndices);
}

protected DataFrameTransformConfig.Builder createTransformConfigBuilder(String id,
protected TransformConfig.Builder createTransformConfigBuilder(String id,
Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
AggregatorFactories.Builder aggregations,
AggregatorFactories.Builder aggregations,

Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
String... sourceIndices) throws Exception {
return createTransformConfig(id, groups, aggregations, destinationIndex, QueryBuilders.matchAllQuery(), sourceIndices);
}

protected DataFrameTransformConfig.Builder createTransformConfigBuilder(String id,
protected TransformConfig.Builder createTransformConfigBuilder(String id,
Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
String destinationIndex,
String destinationIndex,

Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
String... sourceIndices) throws Exception {
return createTransformConfig(id, groups, aggregations, destinationIndex, QueryBuilders.matchAllQuery(), sourceIndices);
}

protected DataFrameTransformConfig.Builder createTransformConfigBuilder(String id,
protected TransformConfig.Builder createTransformConfigBuilder(String id,
Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
QueryBuilder queryBuilder,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
QueryBuilder queryBuilder,
QueryBuilder queryBuilder,

Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
String... sourceIndices) throws Exception {
return createTransformConfig(id, groups, aggregations, destinationIndex, QueryBuilders.matchAllQuery(), sourceIndices);
}

protected DataFrameTransformConfig.Builder createTransformConfigBuilder(String id,
protected TransformConfig.Builder createTransformConfigBuilder(String id,
Map<String, SingleGroupSource> groups,
AggregatorFactories.Builder aggregations,
String destinationIndex,
QueryBuilder queryBuilder,
String... sourceIndices) throws Exception {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
String... sourceIndices) throws Exception {
String... sourceIndices) throws Exception {

@@ -218,7 +218,7 @@ protected DataFrameTransformConfig createTransformConfig(String id,
.setDescription("Test transform config id: " + id);
}

protected DataFrameTransformConfig createTransformConfig(String id,
protected TransformConfig createTransformConfig(String id,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#nit indention

@hendrikmuhs
Copy link
Author

run elasticsearch-ci/bwc

@hendrikmuhs hendrikmuhs merged commit fd3dc4d into elastic:master Sep 25, 2019
hendrikmuhs pushed a commit that referenced this pull request Sep 25, 2019
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants