Skip to content
Open
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 @@ -35,7 +35,7 @@ public DiscoverDatasetResult(final List<DatasetDescription> datasetDescriptionLi
}

@Getter
public final static class DatasetDescription {
public static final class DatasetDescription {

public DatasetDescription(final String name) {
this.name = name;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ public Collection<UiSchema.NameValue> get() {
}

@Data
public static abstract class BaseModel {
public abstract static class BaseModel {

@View.Skip
private String id;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ public static Write write(final Processor output) {
return new Write(output);
}

public static abstract class Base<A extends PInput, B extends POutput, D extends Lifecycle>
public abstract static class Base<A extends PInput, B extends POutput, D extends Lifecycle>
extends PTransform<A, B> {

protected D delegate;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@

public class AvroRecord implements Record, AvroPropertyMapper, Unwrappable {

public final static ZoneId UTC = ZoneId.of("UTC");
public static final ZoneId UTC = ZoneId.of("UTC");

private static final RecordConverters RECORD_CONVERTERS = new RecordConverters();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,10 @@
public class BeamIOWrappingTest implements Serializable {

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@ClassRule
public static transient final TemporaryFolder TEMPORARY_FOLDER = new TemporaryFolder();
public static final transient TemporaryFolder TEMPORARY_FOLDER = new TemporaryFolder();

@Test
public void nativeBeamPipeline() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ public class NativeWrappedIOTest {
.withIsolatedPackage(JdbcSource.class.getPackage().getName(), JdbcIO.class.getPackage().getName());

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
public void dofn() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ public class TalendIOTest implements Serializable {
private static final Jsonb JSONB = JsonbBuilder.create();

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
public void input() {
Expand Down Expand Up @@ -328,7 +328,7 @@ public static class SampleLength implements Serializable {
private int len;
}

private static abstract class BaseTestProcessor implements Serializable, Processor {
private abstract static class BaseTestProcessor implements Serializable, Processor {

@Override
public void beforeGroup() {
Expand Down Expand Up @@ -366,7 +366,7 @@ public void stop() {
}
}

private static abstract class BaseTestInput implements Serializable, Input {
private abstract static class BaseTestInput implements Serializable, Input {

@Override
public String plugin() {
Expand Down Expand Up @@ -394,7 +394,7 @@ public void stop() {
}
}

private static abstract class TheTestMapper implements Serializable, Mapper {
private abstract static class TheTestMapper implements Serializable, Mapper {

@Override
public boolean isStream() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@
@Slf4j
class BeamJobTest implements Serializable {

private transient final PluginGenerator pluginGenerator = new PluginGenerator();
private final transient PluginGenerator pluginGenerator = new PluginGenerator();

@Test
void complex(final TestInfo info, @TempDir final Path temporaryFolder) throws IOException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1302,7 +1302,7 @@
}
};

abstract public Map<String, ? extends ComponentFamilyMeta.BaseMeta> findMeta(ComponentFamilyMeta family);
public abstract Map<String, ? extends ComponentFamilyMeta.BaseMeta> findMeta(ComponentFamilyMeta family);

Check failure on line 1305 in component-runtime-manager/src/main/java/org/talend/sdk/component/runtime/manager/ComponentManager.java

View check run for this annotation

sonar-rnd / SonarQube Code Analysis

component-runtime-manager/src/main/java/org/talend/sdk/component/runtime/manager/ComponentManager.java#L1305

Remove usage of generic wildcard type.

abstract Class<? extends Lifecycle> runtimeType();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,7 @@ public Object decode(final byte[] value, final Type expectedType) {
}

@AllArgsConstructor
private static abstract class BaseResponse<T> implements Response<T> {
private abstract static class BaseResponse<T> implements Response<T> {

private final int status;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ interface InstanceCreator {
}

@AllArgsConstructor
final static class ReflectionInstanceCreator implements InstanceCreator {
static final class ReflectionInstanceCreator implements InstanceCreator {

private final ReflectionService reflections;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,10 +44,10 @@ void generate() throws NoSuchMethodException {
}

@Service
static public class Service1 {
public static class Service1 {
}

@Service
static public class Service2 extends BaseService {
public static class Service2 extends BaseService {
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ public class DataInput implements Serializable {

private final String tableName;

public DataInput(final @Option("tableName") String tableName, final Jsonb jsonb, final I18nService i18n) {
public DataInput(@Option("tableName") final String tableName, final Jsonb jsonb, final I18nService i18n) {
this.tableName = tableName;
this.jsonb = jsonb;
this.i18n = i18n;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public class MapperWithCheckpoint implements Serializable {

private int partition = -1;

public MapperWithCheckpoint(final @Option("configuration") MapperWithCheckpointConfig config,
public MapperWithCheckpoint(@Option("configuration") final MapperWithCheckpointConfig config,
final RecordBuilderFactory recordBuilderFactory) {
this.config = config;
this.recordBuilderFactory = recordBuilderFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public class ProcessorTest {
new SimpleComponentRule(SampleProcessor.class.getPackage().getName());

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
public void processor() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@
public class SampleProcessor implements Serializable {

@ElementListener
public void onNext(final @Input Sample sample, final @Output OutputEmitter<Sample> success,
final @Output("reject") OutputEmitter<Reject> reject) {
public void onNext(@Input final Sample sample, @Output final OutputEmitter<Sample> success,
@Output("reject") final OutputEmitter<Reject> reject) {

success.emit(sample);
reject.emit(new Reject(sample, "error"));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ public abstract class BaseSpark<T extends BaseSpark<?>> {

protected abstract File getRoot();

protected final static String EXTRA_JVM_ARGS =
protected static final String EXTRA_JVM_ARGS =
"--add-opens=java.base/java.nio=ALL-UNNAMED --add-opens=java.base/sun.nio.ch=ALL-UNNAMED";

public T withSlaves(final int slaves) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
@Version(migrationHandler = AbstractMigrationHandler.DataSetHandler.class)
public class MigrationDataSet implements Serializable {

public final static int Version = -1;
public static final int Version = -1;

Check failure on line 31 in component-server-parent/component-server/src/test/java/org/talend/sdk/component/server/test/migration/MigrationDataSet.java

View check run for this annotation

sonar-rnd / SonarQube Code Analysis

component-server-parent/component-server/src/test/java/org/talend/sdk/component/server/test/migration/MigrationDataSet.java#L31

Rename this constant name to match the regular expression '^[A-Z][A-Z0-9]*(_[A-Z0-9]+)*$'.

@Option
private final MigrationDataStore dataStore;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ public class {{testClassName}} {
public static final SimpleComponentRule COMPONENT_FACTORY = new SimpleComponentRule("{{rootPackage}}");

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
@Ignore("You need to complete this test with your own data and assertions")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ public class {{testClassName}} implements Serializable {
public static final SimpleComponentRule COMPONENT_FACTORY = new SimpleComponentRule("{{rootPackage}}");

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
@Ignore("You need to complete this test with your own data and assertions")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,8 @@
}

@ElementListener
public void onNext(@Input final JsonObject record, final @Output OutputEmitter<JsonObject> success,
final @Output("reject") OutputEmitter<Reject> reject) {
public void onNext(@Input final JsonObject record, @Output final OutputEmitter<JsonObject> success,

Check warning on line 69 in component-starter-server/src/test/java/org/talend/sdk/component/starter/server/front/apidemo/component/output/MockOutput.java

View check run for this annotation

sonar-rnd / SonarQube Code Analysis

component-starter-server/src/test/java/org/talend/sdk/component/starter/server/front/apidemo/component/output/MockOutput.java#L69

Rename this variable to not match a restricted identifier.
@Output("reject") final OutputEmitter<Reject> reject) {
try {
JsonObject newRec;
String sysId = null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ public class TInMapperBeamTest implements Serializable {
public static final SimpleComponentRule COMPONENT_FACTORY = new SimpleComponentRule("com.foo");

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
@Ignore("You need to complete this test with your own data and assertions")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ public class TInOutputBeamTest {
public static final SimpleComponentRule COMPONENT_FACTORY = new SimpleComponentRule("com.foo");

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
@Ignore("You need to complete this test with your own data and assertions")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public class TInProcessorBeamTest {
public static final SimpleComponentRule COMPONENT_FACTORY = new SimpleComponentRule("com.foo");

@Rule
public transient final TestPipeline pipeline = TestPipeline.create();
public final transient TestPipeline pipeline = TestPipeline.create();

@Test
@Ignore("You need to complete this test with your own data and assertions")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public class InMemoryQueueIOTest implements Serializable {
private static final Collection<Record> INPUT_OUTPUTS = new CopyOnWriteArrayList<>();

@Rule
public transient final TestPipeline pipeline =
public final transient TestPipeline pipeline =
TestPipeline.fromOptions(PipelineOptionsFactory.fromArgs("--blockOnRun=false").create());

@Test(timeout = 60000)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ class TaCoKitGuessSchemaTest {

private final Pattern logPattern = Pattern.compile("^\\[\\s*(INFO|WARN|ERROR|DEBUG|TRACE)\\s*]");

private final static java.io.PrintStream stdout = System.out;
private static final java.io.PrintStream stdout = System.out;

@BeforeAll
static void forceManagerInit() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -296,13 +296,13 @@ public Schema guessProcessorSchemaKo0() {
}

@DiscoverSchemaExtended("schema")
public Schema guessProcessorSchemaKo1(final Schema schema, final @Option FakeDataSet configuration,
public Schema guessProcessorSchemaKo1(final Schema schema, @Option final FakeDataSet configuration,
final String outgoing) {
return null;
}

@DiscoverSchemaExtended("schema")
public Schema guessProcessorSchemaKo2(final Schema schema, final @Option FakeDataSet configuration,
public Schema guessProcessorSchemaKo2(final Schema schema, @Option final FakeDataSet configuration,
final String outgoing) {
return null;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public void beforeGroup() {
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,12 +48,12 @@
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

@AfterGroup
public void afterGroup(final @Output JsonObject data) {
public void afterGroup(@Output final JsonObject data) {

Check failure on line 56 in component-tools/src/test/java/org/talend/test/failure/aftergroup/MyComponent2.java

View check run for this annotation

sonar-rnd / SonarQube Code Analysis

component-tools/src/test/java/org/talend/test/failure/aftergroup/MyComponent2.java#L56

Add a nested comment explaining why this method is empty, throw an UnsupportedOperationException or complete the implementation.

}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,12 +48,12 @@
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

@AfterGroup
public void afterGroup(final @Output OutputEmitter<JsonObject> out1, JsonObject out2) {
public void afterGroup(@Output final OutputEmitter<JsonObject> out1, JsonObject out2) {

Check failure on line 56 in component-tools/src/test/java/org/talend/test/failure/aftergroup/MyComponent3.java

View check run for this annotation

sonar-rnd / SonarQube Code Analysis

component-tools/src/test/java/org/talend/test/failure/aftergroup/MyComponent3.java#L56

Add a nested comment explaining why this method is empty, throw an UnsupportedOperationException or complete the implementation.

}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ public void beforeGroup() {
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ public void beforeGroup() {
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ public MyComponent6(@Option("configuration") final MyConfig config) {
}

@ElementListener
public Foo passthrough(final Foo item, final @Output("out1") OutputEmitter<JsonObject> out) {
public Foo passthrough(final Foo item, @Output("out1") final OutputEmitter<JsonObject> out) {
return item;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -383,7 +383,7 @@ public Ui getNewComponentModelForm() {

@GET
@Path("{id}")
public Ui editComponentModelForm(final @PathParam("id") final String id) {
public Ui editComponentModelForm(@PathParam("id") final String id) {
final ComponentModel component = findComponent(id);
final Ui spec = getNewComponentModelForm();
spec.setProperties(component);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -187,7 +187,7 @@ Prototype:
* @return
*/
@DiscoverSchemaExtended("full")
public Schema guessMethodName(final Schema incomingSchema, final @Option("configuration") ConfigClass myConfig, final String branch) {...}
public Schema guessMethodName(final Schema incomingSchema, @Option("configuration") final ConfigClass myConfig, final String branch) {...}

@DiscoverSchemaExtended("incoming_schema")
public Schema guessMethodName(final Schema incomingSchema, final @Option("configuration") ConfigClass myConfig) {...}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,8 @@ public void init() {
}

@ElementListener
public void onNext(@Input final JsonObject record, final @Output OutputEmitter<JsonObject> success,
final @Output("reject") OutputEmitter<Reject> reject) {
public void onNext(@Input final JsonObject record, @Output final OutputEmitter<JsonObject> success,
@Output("reject") final OutputEmitter<Reject> reject) {
try {
JsonObject newRec;
String sysId = null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@
@GridLayout.Row({ "dataset" }) })
public class InputConfig implements Serializable {

public final static int INPUT_CONFIG_VERSION = 3;
public static final int INPUT_CONFIG_VERSION = 3;

@Option
@Documentation("Doc: default dataset documentation without Internationalization.")
Expand Down
Loading
Loading