org.joda.time.DateTime.toString()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(12.1k)|赞(0)|评价(0)|浏览(267)

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

DateTime.toString介绍

暂无

代码示例

代码示例来源：origin: qiurunze123/miaosha

public static String dateToStr(Date date,String formatStr){
  if(date == null){
    return StringUtils.EMPTY;
  }
  DateTime dateTime = new DateTime(date);
  return dateTime.toString(formatStr);
}

代码示例来源：origin: qiurunze123/miaosha

public static String dateToStr(Date date){
  if(date == null){
    return StringUtils.EMPTY;
  }
  DateTime dateTime = new DateTime(date);
  return dateTime.toString(STANDARD_FORMAT);
}

代码示例来源：origin: com.thoughtworks.xstream/xstream

public String toString(final Object obj) {
    final DateTime dt = new DateTime(obj);
    return dt.toString(formattersUTC[0]);
  }
}

代码示例来源：origin: azkaban/azkaban

private void cleanExecutionLogs() {
  ExecutorManager.logger.info("Cleaning old logs from execution_logs");
  final long cutoff = System.currentTimeMillis() - this.executionLogsRetentionMs;
  ExecutorManager.logger.info("Cleaning old log files before "
    + new DateTime(cutoff).toString());
  cleanOldExecutionLogs(System.currentTimeMillis()
    - this.executionLogsRetentionMs);
 }
}

代码示例来源：origin: apache/incubator-pinot

public LLCSegmentName(String tableName, int partitionId, int sequenceNumber, long msSinceEpoch) {
 if (!isValidComponentName(tableName)) {
  throw new RuntimeException("Invalid table name " + tableName);
 }
 _tableName = tableName;
 _partitionId = partitionId;
 _sequenceNumber = sequenceNumber;
 // ISO8601 date: 20160120T1234Z
 DateTime dateTime = new DateTime(msSinceEpoch, DateTimeZone.UTC);
 _creationTime = dateTime.toString("yyyyMMdd'T'HHmm'Z'");
 _segmentName = tableName + SEPARATOR + partitionId + SEPARATOR + sequenceNumber + SEPARATOR + _creationTime;
}

代码示例来源：origin: apache/hive

@Override public void configureOutputJobProperties(TableDesc tableDesc, Map<String, String> jobProperties) {
 jobProperties.put(Constants.DRUID_DATA_SOURCE, tableDesc.getTableName());
 jobProperties.put(DruidConstants.DRUID_SEGMENT_VERSION, new DateTime().toString());
 jobProperties.put(DruidConstants.DRUID_JOB_WORKING_DIRECTORY, getStagingWorkingDir().toString());
 // DruidOutputFormat will write segments in an intermediate directory
 jobProperties.put(DruidConstants.DRUID_SEGMENT_INTERMEDIATE_DIRECTORY,
   getIntermediateSegmentDir().toString());
}

代码示例来源：origin: Graylog2/graylog2-server

public TimeRange create(final Map<String, Object> timerangeConfig) throws InvalidRangeParametersException {
    final String rangeType = Strings.isNullOrEmpty((String)timerangeConfig.get("type")) ? (String)timerangeConfig.get("range_type") : (String)timerangeConfig.get("type");
    if (Strings.isNullOrEmpty(rangeType)) {
      throw new InvalidRangeParametersException("range type not set");
    }
    switch (rangeType) {
      case "relative":
        return RelativeRange.create(Integer.parseInt(String.valueOf(timerangeConfig.get("range"))));
      case "keyword":
        return KeywordRange.create((String) timerangeConfig.get("keyword"));
      case "absolute":
        final String from = new DateTime(timerangeConfig.get("from"), DateTimeZone.UTC).toString();
        final String to = new DateTime(timerangeConfig.get("to"), DateTimeZone.UTC).toString();

        return AbsoluteRange.create(from, to);
      default:
        throw new InvalidRangeParametersException("range_type not recognized");
    }
  }
}

代码示例来源：origin: azkaban/azkaban

@Override
public List<Trigger> getUpdatedTriggers(final long lastUpdateTime) throws TriggerLoaderException {
 logger.info("Loading triggers changed since " + new DateTime(lastUpdateTime).toString());
 final ResultSetHandler<List<Trigger>> handler = new TriggerResultHandler();
 try {
  final List<Trigger> triggers = this.dbOperator
    .query(GET_UPDATED_TRIGGERS, handler, lastUpdateTime);
  logger.info("Loaded " + triggers.size() + " triggers.");
  return triggers;
 } catch (final SQLException ex) {
  throw new TriggerLoaderException("Loading triggers from db failed.", ex);
 }
}

代码示例来源：origin: Activiti/Activiti

public static void convertDataPropertiesToJson(List<ValuedDataObject> dataObjects, ObjectNode propertiesNode) {
 ObjectNode dataPropertiesNode = objectMapper.createObjectNode();
 ArrayNode itemsNode = objectMapper.createArrayNode();
 for (ValuedDataObject dObj : dataObjects) {
  ObjectNode propertyItemNode = objectMapper.createObjectNode();
  propertyItemNode.put(PROPERTY_DATA_ID, dObj.getId());
  propertyItemNode.put(PROPERTY_DATA_NAME, dObj.getName());
  String itemSubjectRefQName = dObj.getItemSubjectRef().getStructureRef();
  // remove namespace prefix
  String dataType = itemSubjectRefQName.substring(itemSubjectRefQName.indexOf(':') + 1);
  propertyItemNode.put(PROPERTY_DATA_TYPE, dataType);
  Object dObjValue = dObj.getValue();
  String value = new String();
  if (null == dObjValue) {
   propertyItemNode.put(PROPERTY_DATA_VALUE, "");
  } else {
   if ("datetime".equals(dataType)) {
    value = new DateTime(dObjValue).toString("yyyy-MM-dd'T'hh:mm:ss");
   } else {
    value = new String(dObjValue.toString());
   }
   propertyItemNode.put(PROPERTY_DATA_VALUE, value.toString());
  }
  itemsNode.add(propertyItemNode);
 }
 dataPropertiesNode.set(EDITOR_PROPERTIES_GENERAL_ITEMS, itemsNode);
 propertiesNode.set("dataproperties", dataPropertiesNode);
}

代码示例来源：origin: apache/incubator-gobblin

Path snapshotDir = new Path(this.trashLocation, new DateTime().toString(TRASH_SNAPSHOT_NAME_FORMATTER));
if (this.fs.exists(snapshotDir)) {
 throw new IOException("New snapshot directory " + snapshotDir.toString() + " already exists.");

代码示例来源：origin: alibaba/canal

DateTime dateTime = new DateTime(((java.sql.Time) val).getTime());
if (dateTime.getMillisOfSecond() != 0) {
  res = dateTime.toString("HH:mm:ss.SSS");
} else {
  res = dateTime.toString("HH:mm:ss");
DateTime dateTime = new DateTime(((java.sql.Timestamp) val).getTime());
if (dateTime.getMillisOfSecond() != 0) {
  res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss.SSS+08:00");
} else {
  res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss+08:00");
  res = dateTime.toString("yyyy-MM-dd");
} else {
  if (dateTime.getMillisOfSecond() != 0) {
    res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss.SSS+08:00");
  } else {
    res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss+08:00");
if (dateTime.getHourOfDay() == 0 && dateTime.getMinuteOfHour() == 0 && dateTime.getSecondOfMinute() == 0
  && dateTime.getMillisOfSecond() == 0) {
  res = dateTime.toString("yyyy-MM-dd");
} else if (dateTime.getMillisOfSecond() != 0) {
  res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss.SSS+08:00");
} else {
  res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss+08:00");
    res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss.SSS+08:00");
  } else {

代码示例来源：origin: apache/incubator-gobblin

/**
 * Determine if the {@link Table} or {@link Partition} should be validated by checking if its create time
 * lies between maxLookBackTime and skipRecentThanTime window.
 */
private boolean shouldValidate(Partition partition) {
 for (String pathToken : this.ignoreDataPathIdentifierList) {
  if (partition.getDataLocation().toString().toLowerCase().contains(pathToken.toLowerCase())) {
   log.info("Skipping partition " + partition.getCompleteName() + " containing invalid token " + pathToken
     .toLowerCase());
   return false;
  }
 }
 try {
  long createTime = getPartitionCreateTime(partition.getName());
  boolean withinTimeWindow = new DateTime(createTime).isAfter(this.maxLookBackTime) && new DateTime(createTime)
    .isBefore(this.skipRecentThanTime);
  if (!withinTimeWindow) {
   log.info("Skipping partition " + partition.getCompleteName() + " as create time " + new DateTime(createTime)
     .toString() + " is not within validation time window ");
  } else {
   log.info("Validating partition " + partition.getCompleteName());
   return withinTimeWindow;
  }
 } catch (ParseException e) {
  Throwables.propagate(e);
 }
 return false;
}

代码示例来源：origin: stackoverflow.com

LocalTime localTime = new LocalTime();
LocalDate localDate = new LocalDate();
DateTime dateTime = new DateTime();
LocalDateTime localDateTime = new LocalDateTime();
DateTimeZone dateTimeZone = DateTimeZone.getDefault();
System.out.println("LocalTime : " + localTime.toString());
System.out.println("localDate : " + localDate.toString());
System.out.println("dateTime : " + dateTime.toString());
System.out.println("localDateTime : " + localDateTime.toString());
System.out.println("DateTimeZone : " + dateTimeZone.toString());

代码示例来源：origin: apache/incubator-druid

@Test
 public void testCommonDateTimePattern()
 {
  DateTime dt1 = DateTimes.nowUtc();
  DateTime dt2 = new DateTime(System.currentTimeMillis(), DateTimes.inferTzFromString("IST"));
  DateTime dt3 = new DateTime(System.currentTimeMillis(), DateTimeZone.forOffsetHoursMinutes(1, 30));

  for (DateTime dt : new DateTime[] {dt1, dt2, dt3}) {
   Assert.assertTrue(DateTimes.COMMON_DATE_TIME_PATTERN.matcher(dt.toString()).matches());
  }
 }
}

代码示例来源：origin: azkaban/azkaban

public static Props addCommonFlowProperties(final Props parentProps,
  final ExecutableFlowBase flow) {
 final Props props = new Props(parentProps);
 props.put(CommonJobProperties.FLOW_ID, flow.getFlowId());
 props.put(CommonJobProperties.EXEC_ID, flow.getExecutionId());
 props.put(CommonJobProperties.PROJECT_ID, flow.getProjectId());
 props.put(CommonJobProperties.PROJECT_NAME, flow.getProjectName());
 props.put(CommonJobProperties.PROJECT_VERSION, flow.getVersion());
 props.put(CommonJobProperties.FLOW_UUID, UUID.randomUUID().toString());
 props.put(CommonJobProperties.PROJECT_LAST_CHANGED_BY, flow.getLastModifiedByUser());
 props.put(CommonJobProperties.PROJECT_LAST_CHANGED_DATE, flow.getLastModifiedTimestamp());
 props.put(CommonJobProperties.SUBMIT_USER, flow.getExecutableFlow().getSubmitUser());
 final DateTime loadTime = new DateTime();
 props.put(CommonJobProperties.FLOW_START_TIMESTAMP, loadTime.toString());
 props.put(CommonJobProperties.FLOW_START_YEAR, loadTime.toString("yyyy"));
 props.put(CommonJobProperties.FLOW_START_MONTH, loadTime.toString("MM"));
 props.put(CommonJobProperties.FLOW_START_DAY, loadTime.toString("dd"));
 props.put(CommonJobProperties.FLOW_START_HOUR, loadTime.toString("HH"));
 props.put(CommonJobProperties.FLOW_START_MINUTE, loadTime.toString("mm"));
 props.put(CommonJobProperties.FLOW_START_SECOND, loadTime.toString("ss"));
 props.put(CommonJobProperties.FLOW_START_MILLISSECOND,
   loadTime.toString("SSS"));
 props.put(CommonJobProperties.FLOW_START_TIMEZONE,
   loadTime.toString("ZZZZ"));
 return props;
}

代码示例来源：origin: killbill/killbill

@Test(groups = "fast", description="Test Account event serialization")
  public void testAccountCreationEvent() throws Exception {
    final DefaultAccountData data = new DefaultAccountData("dsfdsf", "bobo", 3, "bobo@yahoo.com", 12, "USD", null, false, UUID.randomUUID(),
                                new DateTime().toString(), "UTC", "US", "21 avenue", "", "Gling", "San Franciso", "CA", "94110", "USA", "4126789887", "notes", false);
    final DefaultAccountCreationEvent e = new DefaultAccountCreationEvent(data, UUID.randomUUID(), 1L, 2L, null);
    final String json = mapper.writeValueAsString(e);

    final DefaultAccountCreationEvent obj = mapper.readValue(json, DefaultAccountCreationEvent.class);
    Assert.assertTrue(obj.equals(e));
  }
}

代码示例来源：origin: apache/incubator-gobblin

new DateTime(record.get("LastModifiedDate")).toString(format));
Assert.assertEquals(jsonRecord.get("date_type").getAsString(),
  new DateTime(record.get("date_type")).toString(format));
  new DateTime(record.get("time_type")).toString(format));
Assert.assertEquals(jsonRecord.get("bytes_type").getAsString().getBytes(),
  ((ByteBuffer) record.get("bytes_type")).array());

代码示例来源：origin: apache/hive

.put("created_date", new DateTime().toString())
.put("start", segment.getInterval().getStart().toString())
.put("end", segment.getInterval().getEnd().toString())
.put("partitioned", !(segment.getShardSpec() instanceof NoneShardSpec))
.put("version", segment.getVersion())

代码示例来源：origin: apache/incubator-pinot

capacity, new DateTime(segmentEndTimeThreshold, DateTimeZone.UTC).toString());
segmentStatusTask = new TimerTask() {
 @Override

代码示例来源：origin: apache/incubator-pinot

_segmentMaxRowCount, new DateTime(_consumeEndTime, DateTimeZone.UTC).toString());
start();

内容来源于网络，如有侵权，请联系作者删除！

DateTime

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    DateTime类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com