Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -1555,7 +1555,6 @@ class BeamModulePlugin implements Plugin<Project> {
"JavaTimeDefaultTimeZone",
"JavaUtilDate",
"JodaConstructors",
"MalformedInlineTag",
"MixedMutabilityReturnType",
"PreferJavaTimeOverload",
"NonCanonicalType",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -596,9 +596,9 @@ DoFnRunner<InputT, OutputT> createBufferingDoFnRunnerIfNeeded(
}

/**
* Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @}
* RequiresStableInput} functionality. By default this is the default keyed backend, but can be
* override in @{link ExecutableStageDoFnOperator}.
* Retrieve a keyed state backend that should be used to buffer elements for
* {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but
* can be override in {@link ExecutableStageDoFnOperator}.
*
* @return the keyed backend to use for element buffering
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -596,9 +596,9 @@ DoFnRunner<InputT, OutputT> createBufferingDoFnRunnerIfNeeded(
}

/**
* Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @}
* RequiresStableInput} functionality. By default this is the default keyed backend, but can be
* override in @{link ExecutableStageDoFnOperator}.
* Retrieve a keyed state backend that should be used to buffer elements for
* {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but
* can be override in {@link ExecutableStageDoFnOperator}.
*
* @return the keyed backend to use for element buffering
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -598,9 +598,9 @@ DoFnRunner<InputT, OutputT> createBufferingDoFnRunnerIfNeeded(
}

/**
* Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @}
* RequiresStableInput} functionality. By default this is the default keyed backend, but can be
* override in @{link ExecutableStageDoFnOperator}.
* Retrieve a keyed state backend that should be used to buffer elements for
* {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but
* can be override in {@link ExecutableStageDoFnOperator}.
*
* @return the keyed backend to use for element buffering
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -240,7 +240,7 @@ default WindowByBuilder<KeyT, ValueT> combineBy(CombineFunctionWithIdentity<Valu
* Syntactic sugar to enable #combineBy to take only single argument and be used in helpers like
* #combineBy(Sums.ofLongs()).
*
* @deprecated Replaced by @{link #combineBy(CombineFunctionWithIdentity)}.
* @deprecated Replaced by {@link #combineBy(CombineFunctionWithIdentity)}.
*/
@Deprecated
default WindowByBuilder<KeyT, ValueT> combineBy(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ default WindowByBuilder<ValueT> combineBy(
* Syntactic sugar to enable #combineBy to take only single argument and be used in helpers like
* #combineBy(Sums.ofLongs()).
*
* @deprecated Replaced by @{link #combineBy(ReduceByKey.CombineFunctionWithIdentity)}.
* @deprecated Replaced by {@link #combineBy(ReduceByKey.CombineFunctionWithIdentity)}.
*/
@Deprecated
default WindowByBuilder<ValueT> combineBy(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;

/** Test suite for @{link Sums}. */
/** Test suite for {@link Sums}. */
@RunWith(JUnit4.class)
public class SumsTest {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
import java.io.Serializable;

/**
* Provided by user and called within {@link org.apache.beam.sdk.transforms.DoFn.Setup} and @{link
* Provided by user and called within {@link org.apache.beam.sdk.transforms.DoFn.Setup} and {@link
* org.apache.beam.sdk.transforms.DoFn.Teardown} lifecycle methods of {@link Call}'s {@link
* org.apache.beam.sdk.transforms.DoFn}.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
import java.util.List;
import org.apache.beam.sdk.io.range.OffsetRange;

/** Determines bundle sizes based on @{link SyntheticSourceOptions}. */
/** Determines bundle sizes based on {@link SyntheticSourceOptions}. */
public class BundleSplitter implements Serializable {

private SyntheticSourceOptions options;
Expand Down
Loading