org.datacleaner.api.Distributed.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(5.7k)|赞(0)|评价(0)|浏览(176)

本文整理了Java中org.datacleaner.api.Distributed.<init>()方法的一些代码示例,展示了Distributed.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Distributed.<init>()方法的具体详情如下:
包路径:org.datacleaner.api.Distributed
类名称:Distributed
方法名:<init>

Distributed.<init>介绍

暂无

代码示例

代码示例来源:origin: datacleaner/DataCleaner

/**
 * Defines abstract methods, metrics etc. for analyzer results of the Value
 * Distribution analyzer.
 */
@Distributed(reducer = ValueDistributionAnalyzerResultReducer.class)
public abstract class ValueDistributionAnalyzerResult extends AbstractValueCountingAnalyzerResult {

  private static final long serialVersionUID = 1L;

  @Metric("Total count")
  @Override
  public abstract int getTotalCount();

  @Metric("Null count")
  @Override
  public abstract int getNullCount();

  @Metric("Unique count")
  @Override
  public abstract Integer getUniqueCount();

  @Metric("Distinct count")
  @Override
  public abstract Integer getDistinctCount();
}

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = CharacterSetDistributionResultReducer.class)
public class CharacterSetDistributionResult extends CrosstabResult {

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = WriteDataResultReducer.class)
public interface WriteDataResult extends AnalyzerResult {

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = CategorizationResultReducer.class)
public class CategorizationResult implements AnalyzerResult {

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = NumberAnalyzerResultReducer.class)
public class NumberAnalyzerResult extends CrosstabResult {

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = ValueMatchAnalyzerResultReducer.class)
public class ValueMatchAnalyzerResult extends AbstractValueCountingAnalyzerResult {

代码示例来源:origin: org.eobjects.datacleaner/DataCleaner-mark-rows

@Description("Marked rows")
@Distributed(reducer = MarkRowsAnalyzerResultReducer.class)
public class MarkRowsAnalyzerResult extends AnnotatedRowsResult {

  private static final long serialVersionUID = 1L;

  public MarkRowsAnalyzerResult(RowAnnotation annotation, RowAnnotationFactory annotationFactory,
      InputColumn<?>[] highlightedColumns) {
    super(annotation, annotationFactory, highlightedColumns);
  }

  @Metric(order = 1, value = "Row count")
  public int getTotalRowCount() {
    return getAnnotatedRowCount();
  }
}

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(true)
abstract class AbstractQueryOptimizedRangeFilter<E>
    implements QueryOptimizedFilter<RangeFilterCategory>, Comparator<E>, HasLabelAdvice {

代码示例来源:origin: datacleaner/DataCleaner

@Description("Records with unresolved foreign key values")
@Distributed(reducer = ReferentialIntegrityAnalyzerReducer.class)
public class ReferentialIntegrityAnalyzerResult extends AnnotatedRowsResult {

  private static final long serialVersionUID = 1L;

  public ReferentialIntegrityAnalyzerResult(final RowAnnotation annotation,
      final RowAnnotationFactory annotationFactory, final InputColumn<?>[] highlightedColumns) {
    super(annotation, annotationFactory, highlightedColumns);
  }
}

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = PatternFinderResultReducer.class)
public class PatternFinderResult implements AnalyzerResult {

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = StringAnalyzerResultReducer.class)
public class StringAnalyzerResult extends CrosstabResult {

代码示例来源:origin: datacleaner/DataCleaner

@Description("Marked rows")
@Distributed(reducer = MarkRowsAnalyzerResultReducer.class)
public class MarkRowsAnalyzerResult extends AnnotatedRowsResult {

  private static final long serialVersionUID = 1L;

  public MarkRowsAnalyzerResult(RowAnnotation annotation, RowAnnotationFactory annotationFactory,
      InputColumn<?>[] highlightedColumns) {
    super(annotation, annotationFactory, highlightedColumns);
  }

  @Metric(order = 1, value = "Row count")
  public int getTotalRowCount() {
    return getAnnotatedRowCount();
  }
}

代码示例来源:origin: datacleaner/DataCleaner

@Distributed(reducer = CompletenessAnalyzerResultReducer.class)
public class CompletenessAnalyzerResult extends AnnotatedRowsResult implements AnalyzerResult {

代码示例来源:origin: datacleaner/DataCleaner

@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = WeekdayDistributionResultReducer.class)
public class WeekdayDistributionAnalyzer implements Analyzer<CrosstabResult> {

代码示例来源:origin: datacleaner/DataCleaner

@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = DatePartDistributionResultReducer.class)
public class YearDistributionAnalyzer implements Analyzer<CrosstabResult> {

代码示例来源:origin: datacleaner/DataCleaner

@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = MonthDistributionResultReducer.class)
public class MonthDistributionAnalyzer implements Analyzer<CrosstabResult> {

代码示例来源:origin: datacleaner/DataCleaner

+ "location for staging data or simply storing data temporarily for further analysis.")
@Categorized(superCategory = WriteSuperCategory.class)
@Distributed(false)
public class CreateStagingTableAnalyzer extends AbstractOutputWriterAnalyzer implements HasLabelAdvice {

代码示例来源:origin: datacleaner/DataCleaner

@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = DatePartDistributionResultReducer.class)
public class WeekNumberDistributionAnalyzer implements Analyzer<CrosstabResult> {

代码示例来源:origin: datacleaner/DataCleaner

@Description("Filter rows that contain null values.")
@Categorized(FilterCategory.class)
@Distributed(true)
public class NullCheckFilter implements QueryOptimizedFilter<NullCheckFilter.NullCheckCategory>, HasLabelAdvice {

代码示例来源:origin: datacleaner/DataCleaner

@Named("Max rows")
@Description("Sets a maximum number of rows to process.")
@Categorized(value = FilterCategory.class)
@Distributed(false)
public class MaxRowsFilter implements QueryOptimizedFilter<MaxRowsFilter.Category>, HasLabelAdvice {

相关文章

Distributed类方法