Skip to content

[BEAM-65] Adds HasDefaultTracker for RestrictionTracker inference#2462

Closed
jkff wants to merge 2 commits intoapache:masterfrom
jkff:auto-tracker
Closed

[BEAM-65] Adds HasDefaultTracker for RestrictionTracker inference#2462
jkff wants to merge 2 commits intoapache:masterfrom
jkff:auto-tracker

Conversation

@jkff
Copy link
Contributor

@jkff jkff commented Apr 7, 2017

Allows a restriction type to implement HasDefaultTracker, in that case the splittable DoFn itself does not need to implement NewTracker - only ProcessElement and GetInitialRestriction.

R: @tgroh

(this is less urgent to review than #2455 - just nice to have)

@coveralls
Copy link

Coverage Status

Coverage increased (+0.01%) to 69.819% when pulling aa2f643 on jkff:auto-tracker into 82c5e89 on apache:master.

@asfbot
Copy link

asfbot commented Apr 7, 2017

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/beam_PreCommit_Java_MavenInstall/9288/
--none--

public static final String PROCESS_CONTEXT_PARAMETER_METHOD = "processContext";
public static final String ON_TIMER_CONTEXT_PARAMETER_METHOD = "onTimerContext";
public static final String WINDOW_PARAMETER_METHOD = "window";
public static final String INPUT_PROVIDER_PARAMETER_METHOD = "inputProvider";
Copy link
Member

Choose a reason for hiding this comment

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

This removal (although probably sane until we support it) doesn't seem related.

jkff added 2 commits April 7, 2017 15:54
Allows a restriction type to implement HasDefaultTracker,
in that case the splittable DoFn itself does not need to
implement NewTracker - only ProcessElement and GetInitialRestriction.
@asfgit asfgit closed this in 4a694ce Apr 7, 2017
@coveralls
Copy link

Coverage Status

Coverage increased (+0.02%) to 69.828% when pulling c75cfee on jkff:auto-tracker into 4fd8dc4 on apache:master.

@asfbot
Copy link

asfbot commented Apr 7, 2017

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/beam_PreCommit_Java_MavenInstall/9304/
--none--

@jkff jkff deleted the auto-tracker branch April 7, 2017 23:54
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants